# -*- coding: utf-8 -*-
from datetime import timedelta
from  airflow.sensors.date_time import DateTimeSensor

time_after_05_00 = DateTimeSensor(
    task_id='time_after_05_00',
    pool='unlimited_pool',
    target_time='{{ execution_date | date_add(1) | cst_ds }}T05:00:00+08:00',
    retries=0,
    mode='reschedule',
    timeout=timedelta(hours=6).seconds,
)
